using System;
using System.Threading.Tasks;

namespace MessageQueues.Abstractions
{
    /// <summary>
    /// 消息队列上下文
    /// </summary>
    public interface IMqContext
    {
        Task SubscribeAsync<T>(string name, Action<T> action);

        Task PublishAsync<T>(string name, T data);
    }
}